package com.atguigu.bigdata.scala.chapter02

import java.io.{ObjectOutputStream, OutputStream}
import java.net.Socket

import com.atguigu.bigdata.scala.bean.User

object Scala08_Net_Master_Object {

    def main(args: Array[String]): Unit = {

        // TODO 主机
        // 连接从机，发送数据
        val serverSocket : Socket = new Socket("localhost", 9999)
        println("连接从机成功，准备发送数据...");

        // 获取输出流
        val out: OutputStream = serverSocket.getOutputStream
        // 如果在网络中想要传递对象，那么需要使用对象输出流
        // 网络中如果想要传递对象，这个对象需要能够序列化，所以必须实现可序列化接口
        val objOut = new ObjectOutputStream(out)
        // 输出对象
        val user = new User()
        objOut.writeObject(user)
        objOut.flush()
        objOut.close()
        println("对象发送成功...");

        serverSocket.close()
    }
}
